package com.hudsonmq.spring.impl.consume;

import com.hudson.codec.domain.MessageExt;

import java.util.List;

/**
 * @Author: 渔小鲤
 * @DateTime: 2025/7/12 14:07
 **/
public interface HudsonMQHandler {

    void onMessage(byte[] message) throws Exception;

    void retry(List<MessageExt> message);
}
